import threading
from Queue import Queue
from time import sleep

class CustomTask():
    def __init__(self,fn):
        self.fn = fn

    def run(self,*args):
        result = apply(self.fn,args)
        self._result = result

    def get_result(self):
        return self._result
    
